package com.etl.process.prepare.config;

/**
 * 准备级别
 * mq接收消息 状态
 */
public class MqMessageStatusPrepare {

    /**
     * 需要启动两个
     * etl-modules-process-schedule 也许要启动服务
     * 所有的信息存储redis
     * 要不保证数据同步
     * 两个服务保证数据同步  放入redis不需要
     * 需要装栽集群
     */


    /**
     * 准备MqMessageStatus
     *  注意目前不是交换机模式 而是工作模式
     *
     * 1.注册 bean
     * 注册 队列 queue -》规定 start_start
     *
     * 2.数据监听 listens
     *  2.1 数据准备 监听队列发送的信息
     *     2.1.1 进行sql拼接
     *     2.1.2 数据分段
     *     2.1.3 准备连接池  给执行 etl-modules-process-execute_task 发送信息  此队列为交换机广播模式
     *     2.1.4 心跳
     *  2.2 注意每个队列都有回制 给 -》 start_start
     *     2.2.1 发送消息给回制队列 start_task_receipt
     *
     *     回制作用 向上反馈  向下监测
     *     每个环节时间超了会认为异常
     *     回制后才是真正流程
     *
     * 3.给下级发送消息 ready_task  到 etl-modules-process-ready
     *
     */




}
